#数据库
import pymysql

class mysqldb():

    def __init__(self,dataurl, dataname,datapass, database,SQL):
        '''
        dataurl:数据库连接地址
        dataname：数据库用户名
        datapass:数据库用户密码
        database：数据库名
        '''
        self.dataurl = dataurl
        self.dataname = dataname
        self.datapass = datapass
        self.database = database
        self.SQL = SQL
        # 打开数据库连接
        self.coon = pymysql.connect(self.dataurl, self.dataname, self.datapass, self.database, charset='utf8')

        self.cursor = self.coon.cursor()  # 使用cursor()方法获取操作游标


    '''
    查询
    '''
    def Inquire(self):
        try:
            self.cursor.execute(self.SQL)  # 使用execute方法执行SQL语句
            # alldata =self.cursor.fetchone()# 获取单条数据
            # data = self.cursor.fetchmany(3)# 获取前N条数据
            alldata =self.cursor.fetchall()# 获取所有数据
            data_list = []
            for data in alldata:
                data_list.append(data[0])#将元组中的数据在加入到列表中
        except:
            # 发生错误时回滚
            self.coon.rollback()
        self.coon.close()# 关闭数据库连接
        return data_list


    '''
    插入数据、删除表中的数据、更新数据
    '''
    def execute_sql(self):

        try:
            # 执行sql语句
            self.cursor.execute(self.SQL)
            # 执行sql语句
            self.coon.commit()
        except:
            # 发生错误时回滚
            self.coon.rollback()

        self.coon.close()  # 关闭数据库连接


    # '''删除表中的数据'''
    # def Delete(self):
    #     try:
    #         # 执行SQL语句
    #         self.cursor.execute(self.SQL)
    #         # 提交修改
    #         self.coon.commit()
    #     except:
    #         # 发生错误时回滚
    #         self.coon.rollback()
    #     self.coon.close()  # 关闭数据库连接





if __name__ =='__main__':
    dataurl = "rm-bp1rlhj38wp2e6h135o.mysql.rds.aliyuncs.com"
    dataname = "joinhealth"
    datapass = "ANIAUd74DHunIUDW"
    database = "interview_manage"
    SQL = "select hosp_name FROM t_manage_hospital_permission where hosp_code='756286168'"
    SQL = "select hosp_name FROM t_manage_hospital_permission where hosp_code='756286168'"
    db=mysqldb(dataurl,dataname,datapass,database,SQL)
    data=db.Inquire()
    print(data)
